package com.beta.mq.redis.producer;

import com.beta.mq.redis.model.Message;

/**
 * @author taofucheng
 * @date 2015/12/8.
 */
public interface Producer {

    void sendMessage(String topic, Message message) throws InterruptedException;
}
